package pool;

import eval.Batch;
import network.Rule;
import partition.SubspacePartition;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class JobGroup {
    private BlockingQueue<Rule> pendingUpdates;
    private Map<Integer, SubspacePartition> hsToSubspacePartition;

    public JobGroup() {
        this.pendingUpdates = new LinkedBlockingQueue<>();
        this.hsToSubspacePartition = new HashMap<>();
    }

    public void addJob(Integer hs, SubspacePartition subspacePartition) {
        this.hsToSubspacePartition.put(hs, subspacePartition);
    }
}
